package cn.anjubao.cp.api.config.mq;

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;

@Configuration
@ConfigurationProperties(prefix = "mq")
@Data
public class RocketMQProperties {

    private String namesrv;

    private Consumer consumer = new RocketMQProperties.Consumer();

    private Producer producer = new RocketMQProperties.Producer();

    @Data
    public static class Consumer {
        private String group;

        private String topic;
    }

    @Data
    public static class Producer {
        private String group;
    }
}
